package com.example.mq.common;

import jdk.nashorn.internal.objects.annotations.Constructor;
import lombok.Data;
import lombok.Getter;
import lombok.Setter;

/**
 * 表示一个消费者（完整的执行环境）
 */
@Data
public class ConsumerEnv {
    private String consumerTag;//消费者的身份标识
    private String queueName;//消费的那个队列
    //消息被消费完成后, 应答的方式. 为 true 自动应答. 为 false 手动应答.
    private boolean autoAck;
    //处理收到的消息一个回调函数. 此处类型设定成函数式接口. 这样后续调用 basicConsume 并且传实参的时候, 就可以写作 lambda 样子了.
    private Consumer consumer;
    public ConsumerEnv(String consumerTag, String queueName, boolean autoAck, Consumer consumer) {
        this.consumerTag = consumerTag;
        this.queueName = queueName;
        this.autoAck = autoAck;
        this.consumer = consumer;
    }

}
